package ar.uba.is2.common.mensaje.protocolo.impl;

import java.util.ArrayList;
import java.util.Collection;

import org.apache.log4j.Logger;

import ar.uba.is2.common.mensaje.Mensaje;
import ar.uba.is2.common.mensaje.Receptor;

public class ProtocoloSimple extends ProtocoloAbstracto {

	private static final Logger logger = Logger.getLogger(ProtocoloSimple.class);
	
	private Collection<Receptor> receptores = new ArrayList<Receptor>();
	
	@Override
	public synchronized void enviarMensaje(Mensaje msj) {
		this.canal.enviarMensaje(msj);
	}
	
	@Override
	public void recibirMensaje(Mensaje mensaje) {
		logger.info(String.format("Se recibio el mensaje %s", mensaje));
		
		for (Receptor receptor : this.receptores) {
			receptor.recibirMensaje(mensaje);
		}
	}

	public void registrarReceptor(Receptor receptor) {
		this.receptores.add(receptor);
	}

}
